package com.myflink.day02;

import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

/**
 * @author Shelly An
 * @create 2020/9/16 14:26
 */
public class Environment {
    public static void main(String[] args) {
        //获取批处理 执行环境
        ExecutionEnvironment benv = ExecutionEnvironment.getExecutionEnvironment();
        //获取流处理 执行环境
        StreamExecutionEnvironment senv = StreamExecutionEnvironment.getExecutionEnvironment();

        //Spark在本地执行时会加什么 .setMaster("local[*]") 在代码里指定本地模式  提交yarn的时候是不能写的
        //Flink不需要在代码中区分环境，在源码中帮我们做了
    }
}
